Flink1.11.2 | 您所在的位置:网站首页 › flink 连接pg库输出 demo › Flink1.11.2 |
Flink1.12-RocketMQ4.5.1-Source
qq_39145039: 您好,无法消费数据,但是又不报错改怎么核查 Flink1.12-RocketMQ4.5.1-Sourceqq_39145039: 10:28:25,786 INFO source.RocketMQSource - No restore state for the consumer. 10:28:25,786 INFO source.RocketMQSource - No restore state for the consumer. 10:28:25,794 INFO source.RocketMQSource - No restore state for the consumer. 10:28:25,794 INFO source.RocketMQSource - No restore state for the consumer. 10:28:25,798 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: turboMQSource -> Sink: Print to Std. Out (4/4) (f4aa6cad830065611ee2da6a072ca3e3) switched from DEPLOYING to RUNNING. 10:28:25,798 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: turboMQSource -> Sink: Print to Std. Out (4/4) (f4aa6cad830065611ee2da6a072ca3e3) switched from DEPLOYING to RUNNING. 10:28:25,804 INFO source.RocketMQSource - No restore state for the co Shell(一)基础知识稻草人的肩膀: 评论区开张了 Shell(一)基础知识cepain: 沙发 |
CopyRight 2018-2019 实验室设备网 版权所有 |